package com.frinder.official.akka.persistence;

import com.frinder.official.spring.MyBaseActor;

import static com.frinder.official.akka.persistence.MyPersistentActor3.*;

/**
 * Created by frinder on 2017/10/11.
 */
public class MyDestination extends MyBaseActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(Msg.class, msg -> {
                    // ...
                    getSender().tell(new Confirm(msg.deliveryId), getSelf());
                })
                .build();
    }
}